var fs = require('fs')


//======================================== 读取 ======================================== 

// 创建可读流
var rs = fs.createReadStream('input.txt')

// 设置编码为 utf8。
rs.setEncoding('utf-8')


var data = ''

// 处理流事件 --> data, end, and error
rs.on('data', function (chunk) {
    data += chunk
})

rs.on('end', function (chunk) {
    console.log('read end, data:', data)
})

rs.on('error', function (err) {
    console.log('read err:', err.stack)
})



//======================================== 写入 ======================================== 
var ws = fs.createWriteStream('output.txt')
rs.pipe(ws)

console.log('-------------------------------------- test stream ok --------------------')

